<?php
namespace app\common\timer;

use think\console\Input;
use think\console\Output;
use Workerman\Worker;
use think\Request;
use Workerman\Lib\Timer;
use think\worker\Server;

class Mytimer extends Server
{
    protected $socket = 'websocket://0.0.0.0:2347';

    public function __construct()
    {
        parent::__construct();
        $this->onMessage();
        // 或者这样调用
        $this->worker->onWorkerStart = function($worker)
        {
            //每天读取电量
            Timer::add(600,function () use (&$task) {
                event('Task');
            });
            //每天读取水量
            Timer::add(100,function () use (&$task) {
                event('Water');
            });
            //同步订单数据
            Timer::add(1200,function () use (&$task) {
                event('Cost');
            });
//            //自动生成任务
            Timer::add(180,function () use (&$task) {
                event('Report');
            });
            //自动读取商户信息
            Timer::add(1200,function () use (&$task) {
                event('Merchant');
            });
//            //自动更新商户余额
            Timer::add(230,function () use (&$task) {
                event('updateBalance');
            });
        };
    }
    /**
     * 收到信息
     * @param $connection
     * @param $data
     */
    public function onMessage()
    {
        $this->worker->onMessage = function ($connection, $data) {
//            $connection->send($data . "123");
        };
    }
}
